package com.cert.test.controller;

import com.cert.test.dao.EsQueryDao;
import com.cert.test.server.EsServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.io.IOException;

/**
 * User: zsl
 * Date: 2020年6月19日, 0019
 * Time: 12:20
 * description:
 */

@RestController
@RequestMapping("/es")
public class EsTestController {

    @Autowired
    private EsServer esServer;
    @Autowired
    private EsQueryDao esQueryDao;


    /**
     * 增加es的数据
     * 批量增加es的数据
     * @return
     */
    @GetMapping("/queryEs1")
    public String queryEs1() {
        try {
            esQueryDao.matchAllQuery();

            esQueryDao.termQuery();

            esQueryDao.matchQuery();

        } catch (Exception e) {
            e.printStackTrace();
        }
        return "成功suess";
    }

    /**
     * 增加es的数据
     * 批量增加es的数据
     * @return
     */
    @GetMapping("/addEs")
    public String addEs() {
        try {
            //看是否有 index ,如果没有的话添加索引
            esServer.addIndexEs();
            //看是否有此条数据,如果没有此条数据的话添加数据
            esServer.addEs();

        } catch (IOException e) {
            e.printStackTrace();
        }
        return "成功suess";
    }

    @GetMapping("/addBatchEs")
    public String addBatchEs() {
        try {
//            //看是否有 index ,如果没有的话添加索引
//            esServer.addIndexEs();
            //看是否有此条数据,如果没有此条数据的话添加数据
            esServer.addBatchEs();

        } catch (IOException e) {
            e.printStackTrace();
        }
        return "成功suess";
    }

    /**
     * 查询 es
     * @return
     */
    @GetMapping("/queryEs")
    public String queryEs() {
        try {
            esServer.queryEs();

        } catch (IOException e) {
            e.printStackTrace();
        }
        return "成功suess";
    }


    /**
     * 增加es的数据
     * 批量增加es的数据
     * @return
     */
    @GetMapping("/updateEs")
    public String updateEs() {
        try {
            esServer.updateEs();

        } catch (IOException e) {
            e.printStackTrace();
        }
        return "成功suess";
    }

    @GetMapping("/updateBatchEs")
    public String updateBatchEs() {
        try {
            esServer.upBatchUpdateEs();

        } catch (IOException e) {
            e.printStackTrace();
        }
        return "成功suess";
    }

    /**
     * 增加es的数据
     * 批量增加es的数据
     * @return
     */
    @GetMapping("/delEs")
    public String delEs() {
        try {
            esServer.delEs();

        } catch (IOException e) {
            e.printStackTrace();
        }
        return "成功suess";
    }

    @GetMapping("/delBatchEs")
    public String delBatchEs() {
        try {

            esServer.delBatchEs();

        } catch (IOException e) {
            e.printStackTrace();
        }
        return "成功suess";
    }


    @GetMapping("/")
    public String test() {
        System.out.println("234");
        return "sssuess";
    }

}
